package com.douyu.data.rabbitmq.service.consumer;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;
import sun.plugin2.message.Message;

//@RabbitListener(queues = "queue1")
//@Service
public class Consumer1 {

//    @RabbitHandler
    public void receiveMessage(Message message){
        System.out.println("queue1 收到了消息：" + message.toString());
    }
}
